Test Projects/Lwes-test-listener-console/Program.cs

   1 //
   2 // This file is part of the LWES .NET Binding (LWES.net)
   3 //
   4 // COPYRIGHT© 2009, Phillip Clark (cerebralkungfu[at*g mail[dot*com)
   5 //       original .NET implementation
   6 //
   7 // LWES.net is free software: you can redistribute it and/or modify
   8 // it under the terms of the Lesser GNU General Public License as published by
   9 // the Free Software Foundation, either version 3 of the License, or
  10 // (at your option) any later version.
  11 //
  12 // LWES.net is distributed in the hope that it will be useful,
  13 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  14 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  15 // Lesser GNU General Public License for more details.
  16 //
  17 // You should have received a copy of the Lesser GNU General Public License
  18 // along with LWES.net.  If not, see <http://www.gnu.org/licenses/>.
  19 //
  20 namespace Org.Lwes.Tests
  21 {
  22         using System;
  23         using System.Collections.Generic;
  24         using System.Linq;
  25         using System.Text;
  26         using System.Threading;
  27
  28         using Org.Lwes;
  29         using Org.Lwes.Listener;
  30
  31         class Program
  32         {
  33                 #region Methods
  34
  35                 static void Main(string[] args)
  36                 {
  37                         using (IEventListener listener = EventListener.CreateDefault())
  38                         {
  39                                 EventSink sink = new EventSink();
  40                                 listener.RegisterEventSink(sink).Activate();
  41                                 ManualResetEvent printerExited = new ManualResetEvent(false);
  42                                 bool userChoseToExit = false;
  43                                 int receivedEvents = 0;
  44
  45                                 Console.WriteLine("LWES EventListener -\r\n  This console will continue to queue and print LWES events until\r\n  the user types 'exit' followed by a carriage return.");
  46
  47                                 Object consoleWriteLock = new Object();
  48
  49                                 ThreadPool.QueueUserWorkItem(new WaitCallback((s) =>
  50                                 {
  51                                         Event ev;
  52                                         while (!userChoseToExit)
  53                                         {
  54                                                 if (sink.Events.TryDequeue(out ev))
  55                                                 {
  56                                                         lock (consoleWriteLock)
  57                                                         {
  58                                                                 Console.WriteLine(ev.ToString(true));
  59                                                         }
  60                                                         receivedEvents++;
  61                                                 }
  62                                                 else
  63                                                 {
  64                                                         Thread.Sleep(200);
  65                                                 }
  66                                         }
  67                                         printerExited.Set();
  68                                 }));
  69
  70                                 ThreadPool.QueueUserWorkItem(new WaitCallback((s) =>
  71                                 {
  72                                         while (!userChoseToExit)
  73                                         {
  74                                                 int eventCount = receivedEvents;
  75                                                 Thread.Sleep(2000);
  76                                                 if (eventCount < receivedEvents)
  77                                                 {
  78                                                         lock (consoleWriteLock)
  79                                                         {
  80                                                                 Console.WriteLine("LWES EventListener -\r\n  This console will continue to queue and print LWES events until\r\n  the user types 'exit' followed by a carriage return.");
  81                                                         }
  82                                                 }
  83                                         }
  84                                 }));
  85
  86                                 string input;
  87                                 do
  88                                 {
  89                                         input = Console.ReadLine();
  90                                 } while (!String.Equals(input, "exit", StringComparison.CurrentCultureIgnoreCase));
  91                                 userChoseToExit = true;
  92                                 listener.Dispose();
  93
  94                                 printerExited.WaitOne();
  95                         }
  96                 }
  97
  98                 #endregion Methods
  99
 100                 #region Nested Types
 101
 102                 class EventSink : IEventSink
 103                 {
 104                         #region Fields
 105
 106                         SimpleLockFreeQueue<Event> _incomingEvents = new SimpleLockFreeQueue<Event>();
 107
 108                         #endregion Fields
 109
 110                         #region Properties
 111
 112                         public SimpleLockFreeQueue<Event> Events
 113                         {
 114                                 get { return _incomingEvents; }
 115                         }
 116
 117                         public bool IsThreadSafe
 118                         {
 119                                 get { return false; }
 120                         }
 121
 122                         #endregion Properties
 123
 124                         #region Methods
 125
 126                         public void HandleEventArrival(IEventSinkRegistrationKey key, Event ev)
 127                         {
 128                                 _incomingEvents.Enqueue(ev);
 129                         }
 130
 131                         public GarbageHandlingVote HandleGarbageData(IEventSinkRegistrationKey key, System.Net.EndPoint remoteEndPoint, int priorGarbageCountForEndpoint, byte[] garbage)
 132                         {
 133                                 return GarbageHandlingVote.IgnoreAllTrafficFromEndpoint;
 134                         }
 135
 136                         #endregion Methods
 137                 }
 138
 139                 #endregion Nested Types
 140         }
 141 }